package com.ck.jdk8.reactor;

import reactor.core.publisher.Mono;

import java.time.Duration;

/**
 * @Classname MonoTest
 * @Description TODO
 * @Date 2020/12/16 9:38
 * @Created by lpc
 */
public class MonoTest {


    public static void main(String[] args) throws InterruptedException {
        delayTest();
    }


    public static void  delayTest() throws InterruptedException {
        Mono.delay(Duration.ofSeconds(2))
                .subscribe(System.out::println);
        Thread.sleep(2500);
    }
}
